package coop.tecso.capacitaciones.threads.producer.consumer;

public class Productor extends Thread {
	private Buffer buffer;
	private int cantidadAProducir;

	public Productor(Buffer buffer, int cantidadAProducir) {
		super();
		this.buffer = buffer;
		this.cantidadAProducir = cantidadAProducir;
	}

	@Override
	public void run() {
		for (int i = 0; i < cantidadAProducir; i++) {
			producir();
			buffer.put(i);
		}
	}

	/**
	 * Produce un nuevo elemento para agregar al buffer
	 */
	private void producir() {
		// espera un tiempo simulando la produccion
		try {
			Thread.sleep(2);
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
	}

}
